package com.atguigu.gmall.task.test;

import com.atguigu.gmall.common.constant.MqConst;
import com.atguigu.gmall.common.service.RabbitService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * @author atguigu-mqx
 */
@Component
@EnableScheduling
public class ScheduledTask {

    @Autowired
    private RabbitService rabbitService;


    //  开启一个定时任务. 每隔10秒钟执行一次这个方法
    @Scheduled(cron = "0/10 * * * * ?")
    public void test1(){
        //  定时任务中，发送一个消息给activity. 这个activity 监听消息，将mysql 数据放入缓存!
        System.out.println("终于结束了.....");
        this.rabbitService.sendMsg(MqConst.EXCHANGE_DIRECT_TASK,MqConst.ROUTING_TASK_1,"activity");

    }

    //  每天晚上18点钟清空缓存数据.
    @Scheduled(cron = "* * 18 * * ?")
    public void test2(){
        //  定时任务中，发送一个消息给activity. 这个activity 监听消息，将mysql 数据放入缓存!
        System.out.println("终于结束了.....");
        this.rabbitService.sendMsg(MqConst.EXCHANGE_DIRECT_TASK,MqConst.ROUTING_TASK_18,"end---activity");

    }
}
